package cn.codeartist.springboot.example.rocketmq;

import cn.codeartist.springboot.component.rocketmq.annotation.RocketMQConsumer;
import cn.codeartist.springboot.component.rocketmq.annotation.RocketMQMessageListener;
import cn.codeartist.springboot.example.entity.People;

/**
 * jnai
 *
 * @author 艾江南
 * @date 2020/8/12
 */
@RocketMQConsumer
public class DemoConsumer {

    @RocketMQMessageListener(consumer = "defaultMQPushConsumer")
    public void listener(People msg) {
        System.out.println(msg);
    }
}
